import concurrent.futures
import schedule
import time
# 导入定时任务的文件
from SearchCompany import search_company
from SNGG import sngg
from SSF import ssf
from SWGG import swgg
from ZCKT import zckt

def run_scheduled_tasks(executor):
    """
    使用线程池执行定时任务
    """
    search_company()
    sngg()
    ssf()
    swgg()
    zckt()
    while True:
        schedule.run_pending()
        time.sleep(1)

def create_app():
    # 创建线程池
    with concurrent.futures.ThreadPoolExecutor(max_workers=10) as executor:
        # 在线程池中启动定时任务的检查循环
        executor.submit(run_scheduled_tasks, executor)

if __name__ == '__main__':
    create_app()


import logging
from logging.handlers import RotatingFileHandler
# 配置日志信息
# 设置日志的记录等级
logging.basicConfig(level=logging.INFO)
# 创建日志记录器，指明日志保存的路径、每个日志文件的最大大小，保存日志文件个数上限
file_log_handler = RotatingFileHandler("logs/log",maxBytes=1024*1024*100,backupCount=10)
# 创建日志记录的格式
formatter = logging.Formatter("%(levelname)s %(filename)s:%(lineno)d %(message)s")
# 为刚创建的日志记录器设置日志的记录格式
file_log_handler.setFormatter(formatter)
# 为全局的日志工具对象（flask app 使用的）添加日志记录器
logging.getLogger().addHandler(file_log_handler)